/**
 * Created by lzfto
 * Created time: 2025/05/25
 */
package org.lzfto.flink.demo.table.connector.sink;

import org.apache.flink.api.common.io.OutputFormat;
import org.apache.flink.table.connector.sink.OutputFormatProvider;
import org.apache.flink.table.data.RowData;
import org.lzfto.flink.demo.common.JdbcOptionRecord;

public class CustomJdbcSinkRuntimeProvider implements OutputFormatProvider {
    private JdbcOptionRecord jdbcOption;
    public CustomJdbcSinkRuntimeProvider(  JdbcOptionRecord  jdbcOption) {
        this.jdbcOption = jdbcOption;
    }

	@Override
    public OutputFormat<RowData> createOutputFormat() {
        return (OutputFormat<RowData>) new CustomJdbcOutputFormat(this.jdbcOption);
    }
}
